4f41e048acb731de7d8bc91c5aed3c3b8ed2c81f,cache-tests/src/test/java/org/jsr107/tck/integration/CacheWriterTest.java,CacheWriterTest,shouldWriteThroughUsingInvokeAll_setValue_UpdateEntry,#,407
Before Change
assertEquals(NUMBER_OF_KEYS, cacheWriter.getWriteCount());
assertEquals(0, cacheWriter.getDeleteCount());
cache.invokeAll(keys, new Cache.EntryProcessor<Integer, String, Void>() {
@Override
public Void process(Cache.MutableEntry<Integer, String> entry, Object... arguments) {
entry.setValue(VALUE_PREFIX_UPDATED + entry.getKey());
return null;
}
});
assertEquals(NUMBER_OF_KEYS * 2, cacheWriter.getWriteCount());
assertEquals(0, cacheWriter.getDeleteCount());
After Change
assertEquals(NUMBER_OF_KEYS, cacheWriter.getWriteCount());
assertEquals(0, cacheWriter.getDeleteCount());
cache.invokeAll(keys, new SetEntryWithComputedValueProcessor<Integer>(VALUE_PREFIX_UPDATED, ""));
assertEquals(NUMBER_OF_KEYS * 2, cacheWriter.getWriteCount());
assertEquals(0, cacheWriter.getDeleteCount());
for (Integer key : keys) {